package com.tao.service.rabbitMQ;////DIRECT

//@RabbitListener(bindings =@QueueBinding(
//        // email.Deract.queue 是队列名字，这个名字你可以自定随便定义。
//        value = @Queue(value = "msg.topic.queue",autoDelete = "false"),
//        // order.Deract 交换机的名字 必须和生产者保持一致
//        exchange = @Exchange(value = "direct-exchange-boot",
//                // 这里是确定的rabbitmq模式是：Deract 是以广播模式 、 发布订阅模式
//                type = ExchangeTypes.DIRECT)
//))

import com.tao.pojo.Coding;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@RabbitListener(queues = "msg.topic.queue")

@Component
public class MsgService {
    // @RabbitHandler 代表此方法是一个消息接收的方法。该不要有返回值
    @RabbitHandler
    public void messagerevice(Coding message){
        // 此处省略发邮件的逻辑
        System.out.println("msg Topic-------------->" + message.toString());
    }
}